flume-sink报错 java.lang.IllegalStateException: close() called when transaction is OPEN - you must eit

1. 确认代码无误（根据情况修改，表示若获得不了数据不会自动commit或者rollback）： Event event = channel.take(); if (event == null ...